Add cleanup of old account events

kitsune/users/management/commands/cleanup_old_account_events.py

@@ -0,0 +1,15 @@
+from django.core.management.base import BaseCommand
+from django.utils import timezone
+from datetime import timedelta
+from kitsune.users.models import AccountEvent
+
+
+class Command(BaseCommand):
+    help = "Deletes account events that are older than two years"
+
+    def handle(self, *args, **options):
+        two_years_ago = timezone.now() - timedelta(days=730)  # 2 years * 365 days
+        deleted_count = AccountEvent.objects.filter(created_at__lt=two_years_ago).delete()[0]
+        self.stdout.write(
+            self.style.SUCCESS(f"Successfully deleted {deleted_count} old account events")
+        )

kitsune/users/migrations/0033_delete_old_account_events.py

@@ -0,0 +1,17 @@
+from django.db import migrations
+from django.core.management import call_command
+
+
+def cleanup_old_account_events(apps, schema_editor):
+    call_command('cleanup_old_account_events')
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('users', '0032_profile_account_type_alter_profile_user'),
+    ]
+
+    operations = [
+        migrations.RunPython(cleanup_old_account_events, migrations.RunPython.noop),
+    ]

scripts/cron.py

@@ -384,6 +384,21 @@ def job_update_l10n_contributor_metrics():
     call_command("update_l10n_contributor_metrics")
 
 
+@scheduled_job(
+    "cron",
+    month="*",
+    day="*",
+    hour="02",
+    minute="00",
+    day_of_week=0,
+    max_instances=1,
+    coalesce=True,
+    skip=settings.READ_ONLY,
+)
+def job_cleanup_old_account_events():
+    call_command("cleanup_old_account_events")
+
+
 def run():
     try:
         schedule.start()